package com.factory._13observe.demo3;

import java.util.concurrent.Flow;

/**
 * @author Qinye
 * @date 2023/8/13 16:43
 */
public class MObservable implements Flow.Publisher<String> {
    @Override
    public void subscribe(Flow.Subscriber<? super String> subscriber) {
        subscriber.onNext("1");
        subscriber.onNext("2");
        subscriber.onNext("3");
        subscriber.onComplete();
    }
}
